70c2144e2054f42567107310c0205cd73a85dc07,src/main/java/reactor/core/publisher/FluxPublish.java,State,onNext,#T#,215

Before Change


			}
			
			if (!queue.offer(t)) {
				Throwable ex = Exceptions.failWithOverflow("Queue full?!");
				if (!Exceptions.addThrowable(ERROR, this, ex)) {
					Operators.onErrorDropped(ex);
					return;

After Change


			}
			
			if (!queue.offer(t)) {
				Throwable ex = Operators.onOperatorError(s, Exceptions.failWithOverflow("Queue is full?!"), t);
				if (!Exceptions.addThrowable(ERROR, this, ex)) {
					Operators.onErrorDropped(ex);
					return;